const MongoClient=require("mongodb").MongoClient;

const dbName="blog" ; //数据库的名称
const collectionName="myMind" //数据库下的集合名称
function connect(callback){
    MongoClient.connect("mongodb://localhost:27017",function(err,client){
        //如果连接数据库错误
        if(err){
            console.log("出错了----"+err)
        }
        callback(client);
    })
}
module.exports={ 
    add:function(dbName,collectionName,obj,ds){
            connect(function(client){
               // console.log(client)
                   //没有出错继续执行
                    let db=client.db(dbName);//获取数据库
                    //获取当前数据库下的对应集合
                    let collection=db.collection(collectionName);
                    //获取集合之后就可以对数据库中的集合进行操作了
                   
                    collection.insertMany([obj],function(err,result){
                        if(err){
                            throw err
                        }
                         ds
                    })
           })
    },
    //获取数据中指定集合的数据
    get:function(dbName,collectionName,response){
        connect(function(client) {
            let db=client.db(dbName);//获取数据库
            //获取当前数据库下的对应集合
            let collection=db.collection(collectionName);
            collection.find({}).toArray(function(err,data){
                if(err){
                    console.log("出错了"+err)
                }
                response.send(data);

            })
        })
    }
   


}